package org.shj.thread.book2.chapter08;

import java.util.Random;

public class ClientThread extends Thread{

	private final Channel channel;
	private static final Random random = new Random();
	
	public ClientThread(String name, Channel channel){
		super(name);
		this.channel = channel;
	}
	
	public void run(){
		try{
			for(int i = 0 ; true; i++){
				Request req = new Request(getName(), i);
				channel.putRequest(req);
				Thread.sleep(random.nextInt(1000));
			}
		}catch(InterruptedException e){
			
		}
	}
}
